#include "../mq_server/mq_connection.hpp"

using namespace pxt_mq;
using namespace mq_server;

int main()
{
    ConnectionManager::ptr cmp = std::make_shared<ConnectionManager>();
    cmp->NewConnection(muduo::net::TcpConnectionPtr(), std::make_shared<ConsumerManager>(), ProtobufCodecPtr(), 
        std::make_shared<VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"),threadpool::ptr());
    return 0;
}